package main.scala.demo

import org.apache.spark.{SparkConf, SparkContext}

/**
  * SalesDemo
  *
  * @author zhangyimin
  * @date 2018-09-30 下午3:18
  * @version 1.0
  */
object SalesDemo {

  def main(args: Array[String]): Unit = {
     val conf=new  SparkConf()
    conf.setAppName("mySales")
    conf.setMaster("local")
    val sc=new SparkContext(conf)

    val rdd1=sc.textFile("hdfs://10.16.7.36:9000/data/input/sales")
    //Action操作,触发计算,这一次没有缓存
    println(rdd1.count())
    //缓存数据,但不会触发计算,不会立即缓存,cache是Transformation算子
    rdd1.cache()
    rdd1.checkpoint()
    //触发计算,同时把结果缓存
    println(rdd1.count())
    //最后这次,直接从缓存中读取数据
    println(rdd1.count())

    sc.stop();
  }



}
